//package com.zhs.study.rocketMq.springboot;
//
//import com.zhs.study.rocketMq.constant.IndexConstant;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.spring.core.RocketMQTemplate;
//import org.springframework.stereotype.Service;
//
//import javax.annotation.Resource;
//
///**
// *
// * @Author zhenghuisheng
// * @Date：2025/4/21 21:21
// */
//@Slf4j
//@Service
//public class MQProducerService {
//
//    @Resource
//    private RocketMQTemplate rocketMQTemplate;
//
//    public void sendMessage(String message) {
//        log.info("发送的主题为，{} --- 消息为,{}", IndexConstant.CUSTOM_TOPIC, message);
//        rocketMQTemplate.convertAndSend(IndexConstant.CUSTOM_TOPIC, message);
//    }
//}
